home *** CD-ROM | disk | FTP | other *** search
/ Meeting Pearls 2 / Meeting Pearls Vol. II (1995)(GTI - Schatztruhe)[!].iso / Pearls / arc / XFH / src / xpk.c < prev   
C/C++ Source or Header  |  1994-05-05  |  40KB  |  1,365 lines
  1. /* xpk.c - routines for the master xpk.library. 
  2.    Copyright (C) 1991, 1992, 1993 Kristian Nielsen.
  3.  
  4.    This file is part of XFH, the compressing file system handler.
  5.  
  6.    This program is free software; you can redistribute it and/or modify
  7.    it under the terms of the GNU General Public License as published by
  8.    the Free Software Foundation; either version 2 of the License, or
  9.    (at your option) any later version.
  10.  
  11.    This program is distributed in the hope that it will be useful,
  12.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.    GNU General Public License for more details.
  15.  
  16.    You should have received a copy of the GNU General Public License
  17.    along with this program; if not, write to the Free Software
  18.    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.            */
  19.  
  20. #include "CFS.h"
  21. #include <dossupport.h>
  22.  
  23. #include <utility/hooks.h>
  24. #include <utility/tagitem.h>
  25.  
  26. #include <libraries/xpk.h>
  27.  
  28. #include <string.h>
  29.  
  30. /* These two include files are changing all the time. Hence the #undef. */
  31. #undef XpkFH
  32.  
  33. struct Library *XpkBase;
  34.  
  35.  
  36. #ifndef min
  37. #define min(a,b) ((a)>(b) ? (b) : (a))
  38. #endif
  39.  
  40. /* 'Conditional' tag - passed only if condition true. */
  41. #define TAGIF(c,t) ((c)?(t):TAG_IGNORE)
  42.  
  43. /* Structure for holding an xpk file unpacked in memory. */
  44. struct unpackedxpk {
  45.   struct xpkmemchunk *first,*last,*current;
  46.   LONG currentpos;
  47. };
  48.  
  49. /* Node in linked list of data buffers. */
  50. struct xpkmemchunk {
  51.   struct xpkmemchunk *next;
  52.   LONG abspos;
  53.   LONG size;
  54.   UBYTE *data;      /* MUST be alloced with dosalloc(). */
  55. };
  56.  
  57. struct XpkFH {
  58.   struct CFSFH cfsfh;
  59.   struct unpackedxpk *unpackedxpk;
  60.   LONG filelen;
  61.   UBYTE *InBuf;     /* Buffer last returned by inhook. */
  62.   UBYTE *OutBuf;    /* Buffer last returned by outhook. */
  63.   LONG InBufLen;    /* Of InBuf. (ToDo: Not really used...) */
  64.   LONG OutBufLen;   /* Of OutBuf. (ToDo: Not really used...) */
  65. };
  66.  
  67. struct XpkLock {
  68.   struct CFSLock cfslock;
  69. };
  70.  
  71.  
  72.  
  73. static struct unpackedxpk *newunpackedxpk(void){
  74.   struct unpackedxpk *p;
  75.   
  76.   if(!dalloc(p)) return NULL;
  77.   /* All fields 0 by default. */
  78.   return p;
  79. }
  80.  
  81. /* NOTE: 'data' should be allocated with dosalloc().
  82.  * NOTE ALSO: Memory block may be larger than 'size' (will be freed by
  83.  * dosfree() ).
  84.  */
  85. static BOOL addxpkmemchunk(struct unpackedxpk *p, UBYTE *data, LONG size ){
  86.   struct xpkmemchunk *q;
  87.   
  88.   if(!(dalloc(q))) return FALSE;
  89.   q->next=NULL;
  90.   q->size=size;
  91.   q->data=data;
  92.   if(!p->first){
  93.     q->abspos = 0L;
  94.     p->first=p->current=p->last = q;
  95.   }else{
  96.     q->abspos = p->last->abspos+p->last->size;
  97.     p->last->next = q;
  98.     p->last = q;
  99.   }
  100.   return TRUE;
  101. }
  102.  
  103. static void killunpackedxpk(struct unpackedxpk *p){
  104.   struct xpkmemchunk *q,*r;
  105.   
  106.   for(q=p->first;q;q=r){
  107.     r=q->next;
  108.     dfree(q->data);
  109.     dfree(q);
  110.   }
  111.   dfree(p);
  112. }
  113.  
  114. static BOOL seekunpackedxpk(struct unpackedxpk *p, LONG abspos){
  115.    struct xpkmemchunk *q;
  116.    
  117.    if(abspos < 0 || !p->first || p->last->abspos+p->last->size < abspos)
  118.       return (BOOL) (abspos == 0);
  119.    /* Special case: seek just beyond end. */
  120.    if(p->last->abspos+p->last->size == abspos){
  121.         debug(("Seeking to last position in file: %ld.\n",abspos));
  122.       p->current = p->last;
  123.       p->currentpos = abspos;
  124.         return DOSTRUE;
  125.    }
  126.    /* Start at current pos. if possible. */
  127.    q = p->current->abspos <= abspos ? p->current : p->first;
  128.    while(q->abspos+q->size <= abspos) q = q->next;
  129.    p->current = q;
  130.    p->currentpos = abspos;
  131.    return DOSTRUE;
  132. }
  133.  
  134. static BOOL readunpackedxpk(struct unpackedxpk *p, UBYTE *buf, LONG size){
  135.    struct xpkmemchunk *q;
  136.    LONG len,chunkpos;
  137.    
  138.    if(!p->first)
  139.       return (BOOL) (size==0);
  140.    q = p->current;
  141.    while(size>0){
  142.       if(p->last->abspos+p->last->size <= p->currentpos) return FALSE;
  143.       chunkpos=p->currentpos-q->abspos;
  144.       len = min(size,q->size-chunkpos);
  145.       CopyMem(q->data+chunkpos,buf,len);
  146.       size-=len;
  147.       buf+=len;
  148.       p->currentpos+=len;
  149.       if(p->currentpos >= q->abspos+q->size) q=q->next;
  150.       if(q) p->current = q;
  151.    }
  152.    return TRUE;
  153. }
  154.  
  155.  
  156.  
  157. /*------------------------------------------------------------------------*
  158.  * Hooks for Xpk packing / unpacking.
  159.  */
  160.  
  161. /* Structure for private hook data (glob & Xpkfilehandle). */
  162. struct xpkhookdata {
  163.    glb glob;
  164.    struct XpkFH *fh;
  165. };
  166.  
  167.  
  168. /* Free Xpk input buffer if nessesary. */
  169. static void FreeXpkInBuf(struct XpkFH *fh){
  170.  
  171.    /* debug(("FreeXpkInBuf: Checking if buffers allocated...\n")); */
  172.    if(fh->InBuf){
  173.       /* debug(("FreeXpkInBuf: Freeing buffer: %lx,%ld.\n",fh->InBuf,fh->InBufLen)); */
  174.       dosfree(fh->InBuf);
  175.       fh->InBuf = NULL;
  176.    }
  177. }
  178.  
  179. /* Allocate Xpk input buffer. */
  180. static UBYTE *AllocXpkInBuf(struct XpkFH *fh, LONG size){
  181.  
  182.    /* NOTE: I found out (the hard way...) that Xpk expects a buffer
  183.     * 4 bytes larger than requested ... wierd. */
  184.    size+=4;
  185.    FreeXpkInBuf(fh);
  186.    fh->InBufLen=size;
  187.    if(!(fh->InBuf=dosalloc(size))){
  188.       return 0L;
  189.    }
  190.    return fh->InBuf;
  191. }
  192.  
  193. /* Free Xpk output buffer if nessesary. */
  194. static void FreeXpkOutBuf(struct XpkFH *fh){
  195.  
  196.    /* debug(("FreeXpkOutBuf: Checking if buffers allocated...\n")); */
  197.    if(fh->OutBuf){
  198.       /* debug(("FreeXpkOutBuf: Freeing buffer: %lx,%ld.\n",fh->OutBuf,fh->OutBufLen)); */
  199.       dosfree(fh->OutBuf);
  200.       fh->OutBuf = NULL;
  201.    }
  202. }
  203.  
  204. /* Allocate Xpk output buffer. */
  205. static UBYTE *AllocXpkOutBuf(struct XpkFH *fh, LONG size){
  206.  
  207.    /* NOTE: I found out (the hard way...) that Xpk expects a buffer
  208.     * 4 bytes larger than requested ... wierd. */
  209.    size+=4;
  210.    FreeXpkOutBuf(fh);
  211.    fh->OutBufLen=size;
  212.    if(!(fh->OutBuf=dosalloc(size))){
  213.       return 0L;
  214.    }
  215.    return fh->OutBuf;
  216. }
  217.  
  218. /* Transfer control to actual hook function. Shields the actual */
  219. /* hook functions from any ugly assembler-like register considerations. */
  220.  
  221. static LONG __asm DoXpkHook( register __a0 struct Hook *hook,
  222.                       register __a1 struct XpkIOMsg *msg,
  223.                       register __a2 void *dummy){
  224.   struct xpkhookdata *hookdata = hook->h_Data;
  225.   LONG ret;
  226.   typedef LONG (*myhooktype)(glb, struct XpkFH *, ULONG, UBYTE **, LONG);
  227.    
  228.   ret = (*(myhooktype)hook->h_SubEntry)
  229.     (hookdata->glob, hookdata->fh,msg->Type,(UBYTE **)&msg->Ptr,msg->Size);
  230.   if(ret) msg->IOError = hookdata->glob->ioerr;
  231.   return ret;
  232. }
  233.  
  234.  
  235. /* Calling conventions for hooks. */
  236. /* ToDo: When docs become available, check against this description. */
  237. /* */
  238. /* XpkIOMsg->IOError is set only in case of non-zero hook return value. */
  239. /* */
  240. /* Big problem: What is XIO_SEEK supposed to return in XpkIOMsg->Ptr? */
  241. /* The masterlib does the wierdest things... However, it (currently!) */
  242. /* only needs a non-zero return in case of succes. */
  243. /* */
  244. /* XIO_GETBUF/XIO_WRITE in xpkunpackout(): It is assumed that only one */
  245. /* buffer will be needed at any time, so that a second XIO_GETBUF may */
  246. /* free the buffer returned by the first. It is also assumed that */
  247. /* XIO_WRITE may grab the buffer it is writing if it was allocated by */
  248. /* XIO_GETBUF. */
  249. /* */
  250.  
  251. /* Read() hook for unpacking. */
  252. static LONG xpkunpackin(glb glob, struct XpkFH *fh, ULONG type, UBYTE **buf, LONG size){
  253.    LONG actuallen;
  254.    
  255. /* debug(("UnpackInHook: Type=%ld, Buf=%lx, Len=%ld.\n",type, *buf,size));*/
  256.    switch(type){
  257.      case XIO_READ:
  258.       if(!*buf){
  259.          if(!(*buf=AllocXpkInBuf(fh,size))) return XPKERR_NOMEM;
  260.       }
  261.       if( (actuallen = xRead(glob, fh->cfsfh.xfh, *buf, size)) != size){
  262.          return actuallen >= 0 ? XPKERR_TRUNCATED : XPKERR_IOERRIN;
  263.       }
  264.       break;
  265.      case XIO_WRITE:
  266.       debug(("Error: xpkunpackin(): Xpk attemps to XIO_WRITE.\n"));
  267.       return XPKERR_NOFUNC;
  268.      case XIO_FREE:
  269.      case XIO_ABORT:
  270.       FreeXpkInBuf(fh); 
  271.       break;
  272.      case XIO_GETBUF:
  273.       if(!(*buf=AllocXpkInBuf(fh,size))) return XPKERR_NOMEM;
  274.       break;
  275.      case XIO_SEEK:
  276.       if( xSeek( glob, fh->cfsfh.xfh, size, OFFSET_CURRENT)<0 ){
  277.          return XPKERR_IOERROUT;
  278.       }
  279.       *buf = (APTR) 4L;   /* VERY strange... */
  280.       break;
  281.      case XIO_TOTSIZE:
  282.       /* debug(("..... XIO_TOTSIZE: no action...\n")); */
  283.       break;
  284.      default:
  285.       debug(("*** PANIC: xpkunpackin(): Unknown type of action requested.\n"));
  286.       return XPKERR_NOFUNC;
  287.    }
  288.    
  289.    return XPKERR_OK;
  290. }
  291.  
  292.  
  293. /* Write() hook for unpacking. */
  294. static LONG xpkunpackout(glb glob, struct XpkFH *fh, ULONG type, UBYTE **buf, LONG size){
  295.    
  296. /* debug(("UnpackOutHook: Type=%ld, Buf=%lx, Len=%ld.\n",type,*buf,size)); */
  297.    switch(type){
  298.      case XIO_READ:
  299.       debug(("Error: xpkunpackout(): Xpk attemps to XIO_READ.\n"));
  300.       return XPKERR_NOFUNC;
  301.      case XIO_WRITE:
  302.       if( *buf == fh->OutBuf /* && size == fh->OutBufLen */ ){
  303.          /* Writing our previously allocated buffer. Just add it to */
  304.          /* the filehandle, and mark it as used. */
  305.             /* NOTE: because of safety margin, the added memory block is */
  306.             /* larger than nesseeary. */
  307.  
  308.          /* debug(("Adding previously allocated buffer to filehandle: %lx\n",*buf)); */
  309.          if(!addxpkmemchunk(fh->unpackedxpk,*buf,size)){
  310.             debug(("Error: xpkunpackout(): Cannot add data.\n"));
  311.             return XPKERR_NOMEM;
  312.          }
  313.          fh->OutBuf = NULL;
  314.          fh->OutBufLen = 0L;
  315.       }else{
  316.          UBYTE *newbuf;
  317.          
  318.          /* debug(("Copying data into filehandle.\n")); */
  319.          if( !(newbuf = dosalloc(size)) ){
  320.             debug(("Error: xpkunpackout(): No memory.\n"));
  321.             return XPKERR_NOMEM;
  322.          }
  323.          CopyMem(*buf,newbuf,size);
  324.          if(!addxpkmemchunk(fh->unpackedxpk,newbuf,size)){
  325.             debug(("Error: xpkunpackout(): Cannot add data.\n"));
  326.             dosfree(newbuf);
  327.             return XPKERR_NOMEM;
  328.          }
  329.       }
  330.       break;
  331.      case XIO_FREE:
  332.      case XIO_ABORT:
  333.       FreeXpkOutBuf(fh);
  334.       break;
  335.      case XIO_GETBUF:
  336.       if( !(*buf = AllocXpkOutBuf(fh,size)) ){
  337.          debug(("Error: xpkunpackout(): Cannot get buffer for xpk.\n"));
  338.          return XPKERR_NOMEM;
  339.       }
  340.       /* debug(("xpkunpackout()/XIO_GETBUF: returning buffer %lx\n",*buf)); */
  341.       break;
  342.      case XIO_SEEK:
  343.         /* Strange... Surely this code is wrong? I mean, there's no file
  344.          * handle, is there? Commented out for now. */
  345. /*      if( xSeek( glob, fh->cfsfh.xfh, size, OFFSET_CURRENT)<0 ){ */
  346. /*         return XPKERR_IOERROUT; */
  347. /*      } */
  348. /*      *buf = (APTR) 4L;   /* VERY strange... */
  349.       debug(("Error: xpkunpackout(): Xpk attempts to XIO_SEEK.\n"));
  350.       return XPKERR_NOFUNC;
  351. /*      break; */
  352.      case XIO_TOTSIZE:
  353.       /* debug(("..... XIO_TOTSIZE: no action...\n")); */
  354.       break;
  355.      default:
  356.       debug(("*** PANIC: xpkunpackout(): Unknown type of action requested.\n"));
  357.       return XPKERR_NOFUNC;
  358.    }
  359.    return XPKERR_OK;
  360. }
  361.  
  362.  
  363. /* Hooks for Xpk packing.
  364.  * Currently, these use simple XpkFH file handles. However, I'm hoping
  365.  * to eventually make them use async I/O.
  366.  * NOTE BIEN: these XpkFH are FAKE, and cannot be used as such safely.
  367.  * Specifically, the cfsfh is not valid (though cfsfh.xfh is).
  368.  */
  369.  
  370. /* NOTE: xpkpackin() / xpkpackout() are also used for unpacking. */
  371. /* Read() hook for packing. */
  372. static LONG xpkpackin(glb glob, struct XpkFH *fh, ULONG type, UBYTE **buf, LONG size){
  373.    LONG actuallen;
  374.    
  375. /* debug(("PackInHook: Type=%ld, Buf=%lx, Len=%ld.\n",type, *buf,size));*/
  376.    switch(type){
  377.      case XIO_READ:
  378.       if(!*buf){
  379.          if(!(*buf=AllocXpkInBuf(fh,size))) return XPKERR_NOMEM;
  380.       }
  381.       if( (actuallen = xRead(glob, fh->cfsfh.xfh, *buf, size)) != size){
  382.          return actuallen >= 0 ? XPKERR_TRUNCATED : XPKERR_IOERRIN;
  383.       }
  384.       break;
  385.      case XIO_WRITE:
  386.       debug(("Error: xpkpackin(): Xpk attemps to XIO_WRITE.\n"));
  387.       return XPKERR_NOFUNC;
  388.      case XIO_FREE:
  389.      case XIO_ABORT:
  390.       FreeXpkInBuf(fh); 
  391.       break;
  392.      case XIO_GETBUF:
  393.       if(!(*buf=AllocXpkInBuf(fh,size))) return XPKERR_NOMEM;
  394.       break;
  395.      case XIO_SEEK:
  396.       if( xSeek( glob, fh->cfsfh.xfh, size, OFFSET_CURRENT)<0 ){
  397.          return XPKERR_IOERROUT;
  398.       }
  399.       *buf = (APTR) 4L;   /* VERY strange... */
  400.       break;
  401.      case XIO_TOTSIZE:
  402.       /* debug(("..... XIO_TOTSIZE: no action...\n")); */
  403.       break;
  404.      default:
  405.       debug(("*** PANIC: xpkpackin(): Unknown type of action requested.\n"));
  406.       return XPKERR_NOFUNC;
  407.    }
  408.    
  409.    return XPKERR_OK;
  410. }
  411.  
  412.  
  413. /* Write() hook for packing. */
  414. static LONG xpkpackout(glb glob, struct XpkFH *fh, ULONG type, UBYTE **buf, LONG size){
  415.    
  416. /* debug(("PackOutHook: Type=%ld, Buf=%lx, Len=%ld.\n",type,*buf,size));*/
  417.    switch(type){
  418.      case XIO_READ:
  419.       debug(("Error: xpkpackout(): Xpk attemps to XIO_READ.\n"));
  420.       return XPKERR_NOFUNC;
  421.      case XIO_WRITE:
  422.       if(xWrite(glob, fh->cfsfh.xfh, *buf, size) != size){
  423.          return XPKERR_IOERROUT;
  424.       }
  425.       break;
  426.      case XIO_FREE:
  427.      case XIO_ABORT:
  428.       FreeXpkOutBuf(fh);
  429.       break;
  430.      case XIO_GETBUF:
  431.       if( !(*buf = AllocXpkOutBuf(fh,size)) ){
  432.          debug(("Error: xpkpackout(): Cannot get buffer for xpk.\n"));
  433.          return XPKERR_NOMEM;
  434.       }
  435.       /* debug(("xpkpackout()/XIO_GETBUF: returning buffer %lx\n",*buf)); */
  436.       break;
  437.      case XIO_SEEK:
  438.       if( xSeek( glob, fh->cfsfh.xfh, size, OFFSET_CURRENT)<0 ){
  439.          return XPKERR_IOERROUT;
  440.       }
  441.       *buf = (APTR) 4L;   /* VERY strange... */
  442.       break;
  443.      case XIO_TOTSIZE:
  444.       /* debug(("..... XIO_TOTSIZE: no action...\n")); */
  445.       break;
  446.      default:
  447.       debug(("*** PANIC: xpkpackout(): Unknown type of action requested.\n"));
  448.       return XPKERR_NOFUNC;
  449.    }
  450.    return XPKERR_OK;
  451. }
  452.  
  453.  
  454.  
  455. /*------------------------------------------------------------------------*
  456.  * Low-level interface to Xpk functions.
  457.  */
  458.  
  459.  
  460. /* The following code is there to support pre-2.0 OS versions. The
  461.  * problem is that Xpk insists on doing OpenLibrary() itself, which
  462.  * causes the dreaded ASYNCPKT guru.
  463.  */
  464.  
  465. struct xpkunpackmsg{
  466.    struct Message msg;
  467.    void (*func)();
  468.    glb glob;
  469.    struct TagItem *tags;
  470.    LONG result;
  471. };
  472.  
  473. struct xpkexammsg{
  474.    struct Message msg;
  475.    void (*func)();
  476.    glb glob;
  477.    struct XpkFib *fib;
  478.    struct TagItem *tags;
  479.    LONG result;
  480. };
  481.  
  482. struct xpkpackmsg{
  483.    struct Message msg;
  484.    void (*func)();
  485.    glb glob;
  486.    struct TagItem *tags;
  487.    LONG result;
  488. };
  489.  
  490. static void __asm CallXpkUnpackTags(register __a0 struct xpkunpackmsg *msg){
  491.    struct MsgPort *port;
  492.    
  493.    debug(("Calling XpkUnpack(%lx)...", msg->tags ));
  494.    port = msg->glob->ioport;
  495.    if(msg->glob->ioport=CreatePort(NULL,0L)){
  496.       msg -> result = XpkUnpack(msg->tags);
  497.       DeletePort(msg->glob->ioport);
  498.    }else{
  499.       debug(("(no port)"));
  500.       msg->result = XPKERR_NOMEM;
  501.    }
  502.    msg->glob->ioport = port;
  503.    debug(("=%ld\n",msg->result));
  504. }
  505.  
  506.  
  507. static void __asm CallXpkExamine(register __a0 struct xpkexammsg *msg){
  508.    struct MsgPort *port;
  509.    
  510.    debug(("Calling XpkExamine(%lx,%lx)...", msg->fib, msg->tags ));
  511.    port = msg->glob->ioport;
  512.    if(msg->glob->ioport=CreatePort(NULL,0L)){
  513.       msg -> result = XpkExamine(msg->fib, msg->tags);
  514.       DeletePort(msg->glob->ioport);
  515.    }else{
  516.       debug(("(no port)"));
  517.       msg->result = XPKERR_NOMEM;
  518.    }
  519.    msg->glob->ioport = port;
  520.    debug(("=%ld\n",msg->result));
  521. }
  522.  
  523.  
  524. static void __asm CallXpkPackTags(register __a0 struct xpkpackmsg *msg){
  525.    struct MsgPort *port;
  526.    
  527.    debug(("Calling XpkPack(%lx)...", msg->tags ));
  528.    port = msg->glob->ioport;
  529.    if(msg->glob->ioport=CreatePort(NULL,0L)){
  530.       msg -> result = XpkPack(msg->tags);
  531.       DeletePort(msg->glob->ioport);
  532.    }else{
  533.       debug(("(no port)"));
  534.       msg->result = XPKERR_NOMEM;
  535.    }
  536.    msg->glob->ioport = port;
  537.    debug(("=%ld\n",msg->result));
  538. }
  539.  
  540.  
  541. static LONG MyXpkUnpackTags( glb glob, ULONG firsttag, ... ){
  542.    /* Cannot call xpk from a Task (or handler) before KS 2.0. */
  543.    if( ((struct Library *)glob->DOSBase)->lib_Version >= 36){
  544.       return XpkUnpack( (struct TagItem *)&firsttag );
  545.    }else{
  546.       struct xpkunpackmsg msg,*msg2;
  547.       extern void DoDOSSeg();
  548.       struct MsgPort *procid;
  549.    
  550.       msg.msg.mn_Node.ln_Succ=NULL;
  551.       msg.msg.mn_Node.ln_Pred=NULL;
  552.       msg.msg.mn_Node.ln_Name=NULL;
  553.       msg.msg.mn_Node.ln_Type=NT_MESSAGE;
  554.       msg.msg.mn_Node.ln_Pri=0;
  555.       msg.msg.mn_ReplyPort=glob->xpkport;
  556.       msg.msg.mn_Length=sizeof(msg);
  557.       msg.func=(void (*)()) CallXpkUnpackTags;
  558.       msg.glob = glob;
  559.       msg.tags = (struct TagItem *)&firsttag;
  560.  
  561.       if(!(procid=CreateProc   /* Lets pray that 10K stack is enough... */
  562.         ("XpkUnpack()",glob->mytask->tc_Node.ln_Pri,(BPTR)((ULONG)DoDOSSeg>>2),10000L)))
  563.         return XPKERR_NOMEM;
  564.    
  565.       PutMsg(procid,(struct Message *)&msg);
  566.       do WaitPort(glob->xpkport);
  567.       while(!(msg2=(struct xpkunpackmsg *)GetMsg(glob->xpkport)));
  568.  
  569. #ifdef DEBUG
  570.       if(msg2!=&msg)
  571.          KPrintF("ERROR: bogus return message: &msg=%lx msg2=%lx\n",&msg,msg2);
  572. #endif
  573.       return msg2->result;
  574.    }
  575. }
  576.  
  577. static LONG MyXpkExamine( glb glob, struct XpkFib *fib, ULONG firsttag, ... ){
  578.    /* Cannot call xpk from a Task (or handler) before KS 2.0. */
  579.    if( ((struct Library *)glob->DOSBase)->lib_Version >= 36){
  580.       return XpkExamine( fib, (struct TagItem *)&firsttag );
  581.    }else{
  582.       struct xpkexammsg msg,*msg2;
  583.       extern void DoDOSSeg();
  584.       struct MsgPort *procid;
  585.    
  586.       msg.msg.mn_Node.ln_Succ=NULL;
  587.       msg.msg.mn_Node.ln_Pred=NULL;
  588.       msg.msg.mn_Node.ln_Name=NULL;
  589.       msg.msg.mn_Node.ln_Type=NT_MESSAGE;
  590.       msg.msg.mn_Node.ln_Pri=0;
  591.       msg.msg.mn_ReplyPort=glob->xpkport;
  592.       msg.msg.mn_Length=sizeof(msg);
  593.       msg.func=(void (*)()) CallXpkExamine;
  594.       msg.glob = glob;
  595.       msg.fib = fib;
  596.       msg.tags = (struct TagItem *)&firsttag;
  597.  
  598.       if(!(procid=CreateProc   /* Lets pray that 10K stack is enough... */
  599.         ("XpkExamine()",glob->mytask->tc_Node.ln_Pri,(BPTR)((ULONG)DoDOSSeg>>2),10000L)))
  600.         return XPKERR_NOMEM;
  601.    
  602.       PutMsg(procid,(struct Message *)&msg);
  603.       do WaitPort(glob->xpkport);
  604.       while(!(msg2=(struct xpkexammsg *)GetMsg(glob->xpkport)));
  605.  
  606. #ifdef DEBUG
  607.       if(msg2!=&msg)
  608.          KPrintF("ERROR: bogus return message: &msg=%lx msg2=%lx\n",&msg,msg2);
  609. #endif
  610.       return msg2->result;
  611.    }
  612. }
  613.  
  614. static LONG MyXpkPackTags( glb glob, ULONG firsttag, ... ){
  615.    /* Cannot call Xpk from a Task (or handler) before KS 2.0. */
  616.    if( ((struct Library *)glob->DOSBase)->lib_Version >= 36){
  617.       return XpkPack( (struct TagItem *)&firsttag );
  618.    }else{
  619.       struct xpkpackmsg msg,*msg2;
  620.       extern void DoDOSSeg();
  621.       struct MsgPort *procid;
  622.    
  623.       msg.msg.mn_Node.ln_Succ=NULL;
  624.       msg.msg.mn_Node.ln_Pred=NULL;
  625.       msg.msg.mn_Node.ln_Name=NULL;
  626.       msg.msg.mn_Node.ln_Type=NT_MESSAGE;
  627.       msg.msg.mn_Node.ln_Pri=0;
  628.       msg.msg.mn_ReplyPort=glob->xpkport;
  629.       msg.msg.mn_Length=sizeof(msg);
  630.       msg.func=(void (*)())CallXpkPackTags;
  631.       msg.glob = glob;
  632.       msg.tags = (struct TagItem *)&firsttag;
  633.  
  634.       if(!(procid=CreateProc   /* Lets pray that 10K stack is enough... */
  635.         ("XpkPack()",glob->mytask->tc_Node.ln_Pri,(BPTR)((ULONG)DoDOSSeg>>2),10000L)))
  636.         return XPKERR_NOMEM;
  637.    
  638.       PutMsg(procid,(struct Message *)&msg);
  639.       do WaitPort(glob->xpkport);
  640.       while(!(msg2=(struct xpkpackmsg *)GetMsg(glob->xpkport)));
  641.  
  642. #ifdef DEBUG
  643.       if(msg2!=&msg)
  644.          KPrintF("ERROR: bogus return message: &msg=%lx msg2=%lx\n",&msg,msg2);
  645. #endif
  646.       return msg2->result;
  647.    }
  648. }
  649.  
  650.  
  651. /* This function opens an existing file in the xpk format, unpacking
  652.  * it to memory with the help of the xpk.library. Note that due to
  653.  * limitation in the current interface of xpk.library, the whole file
  654.  * must be unpacked at once, which is more speed efficient (and by far
  655.  * the easiest to implement), but requires rather a lot of memory
  656.  * (potentially requiring the data to reside 2-3 times in main memory
  657.  * simultaneously) and could result in memory fragmentation.
  658.  */
  659. struct XpkFH *XpkOpenOldFile( glb glob, struct FileHandle *xfh ){
  660.    struct XpkFH *fh;
  661.    LONG res;
  662.    LONG inlen;
  663.    struct Hook inhook,outhook;
  664.    struct xpkhookdata indata,outdata;
  665.    
  666.    if(!dalloc(fh)){
  667.       OUTOFMEM;
  668.       return NULL;
  669.    }
  670.    fh->cfsfh.objtype = XPKOBJECT;
  671.    fh->cfsfh.mode = MODE_OLDFILE;
  672.    fh->cfsfh.xfh = xfh;
  673.    fh->cfsfh.f = &Xpkfunc;
  674.    /* fh->cfsfh.filename and fh->cfsfh.parent NULL by default. */
  675.    
  676.    if(!(fh->unpackedxpk=newunpackedxpk())){
  677.       OUTOFMEM;
  678.       dfree(fh);
  679.       return NULL;
  680.    }
  681.    
  682.    inhook.h_Entry = (ULONG (*)())DoXpkHook;
  683.    inhook.h_SubEntry = (ULONG (*)())xpkunpackin;
  684.    indata.glob=glob;
  685.    indata.fh=fh;
  686.    inhook.h_Data = &indata;
  687.    outhook.h_Entry = (ULONG (*)())DoXpkHook;
  688.    outhook.h_SubEntry = (ULONG (*)())xpkunpackout;
  689.    outdata.glob=glob;
  690.    outdata.fh=fh;
  691.    outhook.h_Data = &outdata;
  692.  
  693.    /* Get length of file, if possible. */
  694.    inlen = xFileSizeXfh( glob, xfh );
  695.  
  696.    glob->ioerr = 0L;          /* Set by hookfuncs if adequate. */
  697.    res = MyXpkUnpackTags( glob,
  698.             XPK_InHook, &inhook,
  699.             XPK_OutHook, &outhook,
  700.             XPK_Password, glob->xpkpassword,
  701.             TAGIF(inlen!=-1L,XPK_InLen), inlen,
  702.             TAGIF(glob->xpksetpri,XPK_TaskPri), glob->xpkpri,
  703.             TAG_DONE
  704.          );
  705.     debug(("XpkUnPack() returned: %ld\n",res));
  706.    FreeXpkInBuf(fh);
  707.    FreeXpkOutBuf(fh);
  708.    
  709.    if(res != XPKERR_OK){
  710.       if(!glob->ioerr){
  711.          /* ToDo: Since no adequate AmigaDOS error code exists, we */
  712.          /* should perhaps open a requester to inform the user of */
  713.          /* the problem (showing an XpkErr)? */
  714.          glob->ioerr = ERROR_OBJECT_WRONG_TYPE;  /* More likely out of memory. */
  715.       }
  716.       killunpackedxpk(fh->unpackedxpk);
  717.       dfree(fh);
  718.       return NULL;
  719.    }
  720.    if(fh->unpackedxpk->first)
  721.       fh->filelen = fh->unpackedxpk->last->abspos 
  722.                   + fh->unpackedxpk->last->size; /* else 0 by default. */
  723.    return fh;
  724. }
  725.  
  726.  
  727. /* Perform a XpkExamine() on an UFS file handle. */
  728. BOOL XpkExamine_FH( glb glob, struct FileHandle *xfh, struct XpkFib *fib ){
  729.    LONG res;
  730.    LONG inlen;
  731.    struct XpkFH *fh;
  732.    struct Hook inhook;
  733.    struct xpkhookdata indata;
  734.    
  735.    if(!dalloc(fh)){ /* NOTE: NOT a real xpkfilehandle (only InBuf is used). */
  736.       OUTOFMEM;
  737.       return FALSE;
  738.    }
  739.    fh->cfsfh.xfh = xfh;
  740.  
  741.    inhook.h_Entry = (ULONG (*)())DoXpkHook;
  742.    inhook.h_SubEntry = (ULONG (*)())xpkunpackin;
  743.     indata.glob=glob;
  744.     indata.fh=fh;
  745.    inhook.h_Data = &indata;
  746.  
  747.    /* Get length of file, if possible. */
  748.    inlen = xFileSizeXfh( glob, xfh );
  749.    
  750.    glob->ioerr = 0L;          /* Set by hookfuncs if adequate. */
  751.    res = MyXpkExamine( glob, fib,
  752.             XPK_InHook,&inhook,
  753.             TAGIF(inlen!=-1L,XPK_InLen), inlen,
  754.             TAGIF(glob->xpksetpri,XPK_TaskPri), glob->xpkpri,
  755.             TAG_DONE
  756.          );
  757.     debug(("XpkExamine() returned: %ld\n",res));
  758.    FreeXpkInBuf(fh);
  759.    dfree(fh);
  760.       /* Need a better error message here. */
  761.    if( res && !glob->ioerr ) glob->ioerr = ERROR_OBJECT_WRONG_TYPE;
  762.     return (BOOL)( res==XPKERR_OK );
  763. }    
  764.  
  765.  
  766. /* This is the function that does the actual compression (using xpk) from
  767.  * one file handle to another.
  768.  */
  769. static BOOL XpkPackFH2FH(glb glob, struct FileHandle *srcxfh,
  770.                          LONG inlen, struct FileHandle *dstxfh){
  771.    struct XpkFH *srcxpkfh,*dstxpkfh;  /* NOTE: these are FAKE/invalid. */
  772.    LONG res;
  773.    LONG outlen;                     /* Dummy variable. */
  774.    struct Hook inhook,outhook;
  775.    struct xpkhookdata indata,outdata;
  776.    
  777.    /* Create the two fake XpkFH filehandles for the hooks. */
  778.    if(!dalloc(srcxpkfh)){
  779.       OUTOFMEM;
  780.       return FALSE;
  781.    }
  782.    if(!dalloc(dstxpkfh)){
  783.       OUTOFMEM;
  784.       dfree(srcxpkfh);
  785.       return FALSE;
  786.    }
  787.    srcxpkfh->cfsfh.xfh = srcxfh;   /* Buffer pointers NULL by default. */
  788.    dstxpkfh->cfsfh.xfh = dstxfh;   /* Buffer pointers NULL by default. */
  789.    
  790.    /* Set up hooks. */
  791.    inhook.h_Entry = (ULONG (*)())DoXpkHook;
  792.    inhook.h_SubEntry = (ULONG (*)())xpkpackin;
  793.    indata.glob=glob;
  794.    indata.fh=srcxpkfh;
  795.    inhook.h_Data = &indata;
  796.    outhook.h_Entry = (ULONG (*)())DoXpkHook;
  797.    outhook.h_SubEntry = (ULONG (*)())xpkpackout;
  798.    outdata.glob=glob;
  799.    outdata.fh=dstxpkfh;
  800.    outhook.h_Data = &outdata;
  801.  
  802.    glob->ioerr = 0L;          /* Set by hookfuncs if adequate. */
  803.    res = MyXpkPackTags( glob,
  804.       XPK_InHook,&inhook,
  805.       XPK_OutHook,&outhook,
  806.       XPK_InLen,inlen,
  807.       XPK_PackMethod,glob->packmode,
  808.       XPK_StepDown,glob->stepdown,
  809.       XPK_Password,glob->xpkpassword,
  810.       XPK_GetOutLen,&outlen, /* NOTE: not used, buf xpk.doc says needed. */
  811.       TAGIF(glob->xpksetpri,XPK_TaskPri), glob->xpkpri,
  812.       TAG_DONE
  813.     );
  814.     debug(("XpkPack() returned: %ld\n",res));
  815.    
  816.    FreeXpkInBuf(srcxpkfh);
  817.    FreeXpkOutBuf(dstxpkfh);
  818.    dfree(srcxpkfh);
  819.    dfree(dstxpkfh);
  820.  
  821.    if(res != XPKERR_OK){
  822.       if(!glob->ioerr){
  823.          /* ToDo: Since no adequate AmigaDOS error code exists, we */
  824.          /* should perhaps open a requester to inform the user of */
  825.          /* the problem (showing an XpkErr)? */
  826.          glob->ioerr = ERROR_OBJECT_WRONG_TYPE;  /* More likely out of memory. */
  827.       }
  828.       return FALSE;
  829.    }
  830.    return TRUE;
  831. }
  832.  
  833.  
  834. /* This is the function that does the actual compression (using xpk) from
  835.  * one file handle to another.
  836.  */
  837. static BOOL XpkUnPackFH2FH(glb glob, struct FileHandle *srcxfh,
  838.                          LONG inlen, struct FileHandle *dstxfh){
  839.    struct XpkFH *srcxpkfh,*dstxpkfh;  /* NOTE: these are FAKE/invalid. */
  840.    LONG res;
  841.    struct Hook inhook,outhook;
  842.    struct xpkhookdata indata,outdata;
  843.    
  844.    /* Create the two fake XpkFH filehandles for the hooks. */
  845.    if(!dalloc(srcxpkfh)){
  846.       OUTOFMEM;
  847.       return FALSE;
  848.    }
  849.    if(!dalloc(dstxpkfh)){
  850.       OUTOFMEM;
  851.       dfree(srcxpkfh);
  852.       return FALSE;
  853.    }
  854.    srcxpkfh->cfsfh.xfh = srcxfh;   /* Buffer pointers NULL by default. */
  855.    dstxpkfh->cfsfh.xfh = dstxfh;   /* Buffer pointers NULL by default. */
  856.    
  857.    /* Set up hooks. */
  858.    inhook.h_Entry = (ULONG (*)())DoXpkHook;
  859.    inhook.h_SubEntry = (ULONG (*)())xpkpackin;
  860.    indata.glob=glob;
  861.    indata.fh=srcxpkfh;
  862.    inhook.h_Data = &indata;
  863.    outhook.h_Entry = (ULONG (*)())DoXpkHook;
  864.    outhook.h_SubEntry = (ULONG (*)())xpkpackout;
  865.    outdata.glob=glob;
  866.    outdata.fh=dstxpkfh;
  867.    outhook.h_Data = &outdata;
  868.  
  869.    glob->ioerr = 0L;          /* Set by hookfuncs if adequate. */
  870.    res = MyXpkUnpackTags( glob,
  871.       XPK_InHook,&inhook,
  872.       XPK_OutHook,&outhook,
  873.       XPK_InLen,inlen,
  874.       XPK_Password,glob->xpkpassword,
  875.       TAGIF(glob->xpksetpri,XPK_TaskPri), glob->xpkpri,
  876.       TAG_DONE
  877.     );
  878.    debug(("XpkUnPack() returned: %ld\n",res));
  879.    
  880.    FreeXpkInBuf(srcxpkfh);
  881.    FreeXpkOutBuf(dstxpkfh);
  882.    dfree(srcxpkfh);
  883.    dfree(dstxpkfh);
  884.  
  885.    if(res != XPKERR_OK){
  886.       if(!glob->ioerr){
  887.          /* ToDo: Since no adequate AmigaDOS error code exists, we */
  888.          /* should perhaps open a requester to inform the user of */
  889.          /* the problem (showing an XpkErr)? */
  890.          glob->ioerr = ERROR_OBJECT_WRONG_TYPE;  /* More likely out of memory. */
  891.       }
  892.       return FALSE;
  893.    }
  894.    return TRUE;
  895. }
  896.  
  897.  
  898. /* NOTE BIEN: This function preserves the lock! */
  899. struct XpkFH *XpkOpenOldFileFromCopyOfLock( glb glob, struct XpkLock *lock ){
  900.    struct FileHandle *xfh;
  901.    struct XpkFH *fh;
  902.    
  903.    if(!(xfh = xOpenFromCopyOfLock(glob, lock->cfslock.xlock))){
  904.       debug(("Unable to xOpenFromLock(): %ld.\n",glob->ioerr));
  905.       return NULL;
  906.    }
  907.    fh = XpkOpenOldFile( glob, xfh );
  908.    if(!fh){
  909.       LONG saveioerr = glob->ioerr;
  910.       xClose(glob,xfh);
  911.       glob->ioerr = saveioerr;
  912.    }
  913.    return fh;
  914. }
  915.  
  916.  
  917. /* Check if a given filehandle belongs to an Xpk file. glob->ioerr
  918.  * set and FALSE returned in case of error.
  919.  */
  920.  
  921. BOOL IsXpkFile( glb glob, struct FileHandle *xfh ){
  922.    struct XpkFib fib;
  923.    
  924.    if( !XpkExamine_FH(glob, xfh, &fib) ){
  925.       debug(("Error: IsXpkFile: XpkExamine_FH returned error\n"));
  926.       return FALSE;
  927.    }else if( fib.Type == XPKTYPE_PACKED ){
  928.       return TRUE;
  929.    }else{
  930.       glob->ioerr = 0L;
  931.       return FALSE;
  932.    }
  933. }
  934.  
  935.  
  936. /* This is the main entry to the automatic compression, and is the
  937.  * function passed to TransFormFile().
  938.  */
  939. BOOL PackFile2File(glb glob, struct FileHandle *srcxfh,
  940.                    struct FileHandle *dstxfh, void *dummy){
  941.    LONG srcsize;
  942.    
  943.    srcsize = xGetFileSize(glob, srcxfh);
  944.    if(srcsize == -1L){
  945.       debug(("Error: PackFile2File(): Could not obtain file length.\n"));
  946.       return FALSE;
  947.    }
  948.    return XpkPackFH2FH(glob, srcxfh, srcsize, dstxfh);
  949. }
  950.  
  951.  
  952. /* This function is passed to TransFormFile() to unpack a file to another
  953.  * file (to handle Write() to an Xpk file).
  954.  */
  955. BOOL UnPackFile2File(glb glob, struct FileHandle *srcxfh,
  956.                      struct FileHandle *dstxfh, void *dummy){
  957.    LONG srcsize;
  958.    
  959.    srcsize = xGetFileSize(glob, srcxfh);
  960.    if(srcsize == -1L){
  961.       debug(("Error: UnPackFile2File(): Could not obtain file length.\n"));
  962.       return FALSE;
  963.    }
  964.    return XpkUnPackFH2FH(glob, srcxfh, srcsize, dstxfh);
  965. }
  966.  
  967.  
  968. /*------------------------------------------------------------------------*
  969.  * Virtual functions for Open(), Read(), Lock() etc.
  970.  */
  971.  
  972. LONG Xpk_Read( glb glob, struct XpkFH *fh, UBYTE *buf, LONG len ){
  973.  
  974.    if( fh->unpackedxpk->currentpos+len > fh->filelen )
  975.       len = fh->filelen - fh->unpackedxpk->currentpos;
  976.    if( len <= 0 ) return 0L;
  977.    
  978.    if(!readunpackedxpk(fh->unpackedxpk, buf, len )){
  979.       return -1L;
  980.    }
  981.    return len;
  982. }
  983.  
  984.  
  985. LONG Xpk_Seek( glb glob, struct XpkFH *fh, LONG pos, LONG offset ){
  986.     LONG abspos;
  987.     LONG oldpos = fh->unpackedxpk->currentpos;
  988.    
  989.    if( offset != OFFSET_BEGINNING &&
  990.        offset != OFFSET_CURRENT   &&
  991.        offset != OFFSET_END ){
  992.       debug(("Error: Xpk: Bad offset value for Seek(): %ld\n",offset));
  993.       glob->ioerr = ERROR_ACTION_NOT_KNOWN;
  994.       return -1L;
  995.    }
  996.    abspos = abs_seek_pos( fh->unpackedxpk->currentpos, fh->filelen, pos, offset );
  997.    if( abspos < 0 || abspos > fh->filelen ){
  998.       debug(("Error: Xpk: Bad abs. pos. in Seek(): %ld\n",abspos));
  999.       glob->ioerr = ERROR_SEEK_ERROR;
  1000.       return -1L;
  1001.    }
  1002.     debug(("XpkSeek(): fh=%lx, pos=%ld, offset=%ld, abspos=%ld\n",fh,pos,offset,abspos));
  1003.    seekunpackedxpk(fh->unpackedxpk,abspos);
  1004.    
  1005.    return oldpos;
  1006. }
  1007.  
  1008.  
  1009. BOOL Xpk_Close( glb glob, struct XpkFH *fh ){
  1010.   BOOL res;
  1011.    
  1012.   if(!fh->cfsfh.xfh){
  1013.     debug(("Xpk_Close(): Bad fh.\n"));
  1014.     glob->ioerr = ERROR_OBJECT_WRONG_TYPE;
  1015.     return FALSE;
  1016.   }
  1017.   res = xClose( glob, fh->cfsfh.xfh );
  1018.   if( res ){
  1019.     killunpackedxpk(fh->unpackedxpk);
  1020.     XObjUnStuffFH(glob, &fh->cfsfh);
  1021.     dfree(fh);
  1022.   }else{
  1023.     debug(("ERROR: Xpk: xClose() returned false - mem not freed.\n"));
  1024.   }
  1025.   return res;
  1026. }
  1027.  
  1028.  
  1029. /* Xpk_Write() needs to do some magic to prepare the file for writing. The
  1030.  * idea is to replace the file (on disk) with the unpacked data, then make
  1031.  * the file handle look like a CFSFH.
  1032.  *
  1033.  * One possibility would be to write the data in memory. However, since
  1034.  * the file could have changed since this Open(), it's safer to
  1035.  * uncompress the file again.
  1036.  */
  1037. LONG Xpk_Write(glb glob, struct XpkFH *fh, UBYTE *buf, LONG len){
  1038.   BOOL res;
  1039.   char *filename = fh->cfsfh.filename;
  1040.   struct FileLock *xlock = fh->cfsfh.parent->xlock;
  1041.   struct FileHandle *xfh = fh->cfsfh.xfh;
  1042.   LONG currentpos;
  1043.  
  1044.   if(!glob->allowappend){
  1045.     debug(("Xpk_Write(): Appendmode not set - failing.\n"));
  1046.     glob->ioerr = ERROR_ACTION_NOT_KNOWN;
  1047.     return -1L;
  1048.   }
  1049.   if(!xfh){
  1050.     debug(("XpkWrite(): Bad fh.\n"));
  1051.     glob->ioerr = ERROR_OBJECT_WRONG_TYPE;
  1052.     return -1L;
  1053.   }
  1054.   if(!filename){
  1055.     debug(("Error: Xpk_Write(): no name info.\n"));
  1056.     glob->ioerr = ERROR_ACTION_NOT_KNOWN;
  1057.     return -1L;
  1058.   }
  1059.   debug(("Attempting to uncompress file %s.\n",filename));
  1060.   if(!xChangeMode(glob, CHANGE_FH, xfh, MODE_NEWFILE)){
  1061.     debug(("Error: Xpk_Write(): xChangeMode(): %ld.\n",glob->ioerr));
  1062.     return -1L;
  1063.   }
  1064.   if(-1L == xSeek(glob, xfh, 0L, OFFSET_BEGINNING)){
  1065.     debug(("Error: Xpk_Write(): Could not seek to start: %ld.\n",glob->ioerr));
  1066.     return -1L;
  1067.   }
  1068.   res = TransformXFH(glob, xfh, xlock, filename, UnPackFile2File, NULL);
  1069.   debug(("TransformFile() returned: %ld.\n",res));
  1070.   fh->cfsfh.xfh = xfh = NULL;   /* The handle was closed by TransformFile(). */
  1071.   if(!res){
  1072.     SAVEIOERR;
  1073.     /* Bad luck! The uncompress didn't work. Since our xfh is gone, we'll
  1074.      * have to do some magic to save as much as possible.
  1075.      */
  1076.     if( !(xfh=xOpen(glob, xlock, filename, fh->cfsfh.mode)) ){
  1077.       debug(("Error: File %s could not be re-opened: %d.\n",filename,glob->ioerr));
  1078.       /* Nothing to do about it, really... */
  1079.     }
  1080.     RESTIOERR;
  1081.     return -1L;
  1082.   }
  1083.   if( !(xfh=xOpen(glob, xlock, filename, fh->cfsfh.mode)) ){
  1084.     debug(("Error: File %s could not be re-opened: %d.\n",filename,glob->ioerr));
  1085.     /* Nothing to do about it, really... */
  1086.     return -1L;
  1087.   }
  1088.   fh->cfsfh.xfh = xfh;
  1089.   currentpos = fh->unpackedxpk->currentpos;
  1090.   killunpackedxpk(fh->unpackedxpk);
  1091.   if(!glob->compressreadwrite) XObjUnStuffFH(glob, &fh->cfsfh);
  1092.   XObjStealXpkFH(glob, &fh->cfsfh);
  1093.   if(-1L == xSeek(glob, xfh, currentpos, OFFSET_BEGINNING)){
  1094.     debug(("Error: Xpk_Write(): Could not seek to right pos: %ld.\n",glob->ioerr));
  1095.     return -1L;
  1096.   }else{
  1097.     return XObjWrite(glob, &fh->cfsfh, buf, len);
  1098.   }
  1099. }
  1100.  
  1101.  
  1102. struct XpkLock *XpkMakeLock( glb glob, struct FileLock *xlock, LONG mode ){
  1103.     struct XpkLock *newlock;
  1104.     
  1105.     if( !dalloc(newlock) ){
  1106.         OUTOFMEM;
  1107.         return NULL;
  1108.     }
  1109.     newlock->cfslock.objtype = XPKOBJECT;
  1110.     newlock->cfslock.mode = mode;
  1111.     newlock->cfslock.xlock = xlock;
  1112.     newlock->cfslock.f = &Xpkfunc;
  1113.    newlock->cfslock.refcount = 0;    /* NOTE: NOT used for XpkObject's. */
  1114.     return newlock;
  1115. }
  1116.  
  1117.  
  1118. struct XpkLock *XpkDupLock( glb glob, struct XpkLock *lock ){
  1119.    struct XpkLock *newlock;
  1120.  
  1121.    /* XPKOBJECT locks have their xLocks xDupLock'ed, and the rest of
  1122.     * the fields are just copied vanilla.
  1123.     */
  1124.    if( !dalloc(newlock) ){
  1125.       OUTOFMEM;
  1126.       return 0L;
  1127.    }
  1128.    *newlock = *lock;
  1129.    newlock->cfslock.refcount = 0L;   /* Again: refcount is not used. */
  1130.    if( !(newlock->cfslock.xlock = xDupLock(glob, lock->cfslock.xlock)) ){
  1131.       dfree(newlock);
  1132.       return 0L;
  1133.    }
  1134.    return newlock;   
  1135. }
  1136.  
  1137.  
  1138. /* NOTE BIEN: The parent lock is a XOBJECT, not a XPKOBJECT! */
  1139. struct CFSLock *XpkParentDir( glb glob, struct XpkLock *lock ){
  1140.     struct FileLock *xlock;
  1141.     struct CFSLock *newlock;
  1142.     
  1143.     if( !(xlock = xParentDir(glob, lock->cfslock.xlock)) ){
  1144.         return 0L;
  1145.     }
  1146.     newlock = XObjMakeLock( glob, xlock, ACCESS_READ );
  1147.     if( !newlock ){
  1148.         LONG saveioerr = glob->ioerr;
  1149.         xUnLock(glob, xlock);
  1150.         glob->ioerr = saveioerr;
  1151.     }
  1152.     return newlock;
  1153. }
  1154.  
  1155.  
  1156. /* NOTE BIEN: The parent lock is a XOBJECT, not a XPKOBJECT! */
  1157. struct CFSLock *XpkParentFH( glb glob, struct XpkFH *fh ){
  1158.     
  1159.     return XObjParentFH(glob, &fh->cfsfh);
  1160. }
  1161.  
  1162.  
  1163. BOOL XpkUnLock( glb glob, struct XpkLock *lock ){
  1164.     BOOL err;
  1165.  
  1166.    if(lock->cfslock.refcount){
  1167.       /* This should NOT have happened! */
  1168.       debug(("\n\n***PANIC***: XpkUnLock: Nonzero refcount in lock (%ld).\n",lock->cfslock.refcount));
  1169.       return DOSFALSE;
  1170.    }
  1171.     err = xUnLock(glob, lock->cfslock.xlock);
  1172.       
  1173.     /* Now, what if the UnLock fails? I guess it's best to return FALSE
  1174.      * and let the lock live.
  1175.      */
  1176.     if(!err) return DOSFALSE;
  1177.     dfree(lock);
  1178.     return DOSTRUE;
  1179. }
  1180.  
  1181.  
  1182. BOOL XpkSameLock(glb glob, struct XpkLock *l1, struct XpkLock *l2 ){
  1183.     return (BOOL) (xSameLock( glob, l1->cfslock.xlock, l2->cfslock.xlock ) == LOCK_SAME);
  1184. }
  1185.  
  1186. LONG ATUL ( char *Ptr ){
  1187.     UWORD Index;
  1188.     LONG LW;
  1189.  
  1190.     for (Index=0,LW=0L;Index<8;Index++)
  1191.       LW=(LW<<4)+(LONG)(*Ptr++-'A');
  1192.  
  1193.     return LW;
  1194. }
  1195.  
  1196. BOOL XpkFastModifyFIB( struct FileInfoBlock *FIB ){
  1197.  
  1198.     if( (strncmp( FIB->fib_Comment, XFH_ID, 5 ) != 0) ||
  1199.             (strlen( FIB->fib_Comment ) != 50) ) return FALSE;
  1200.     debug(("XpkFastModifyFIB: header found: %s\n",FIB->fib_Comment));
  1201.  
  1202.     FIB->fib_Comment[0] = '\0';
  1203.     if ( (ATUL( &FIB->fib_Comment[6] ) == FIB->fib_Date.ds_Days) &&
  1204.          (ATUL( &FIB->fib_Comment[15] ) == FIB->fib_Date.ds_Minute) &&
  1205.          (ATUL( &FIB->fib_Comment[24] ) == FIB->fib_Date.ds_Tick) &&
  1206.          (ATUL( &FIB->fib_Comment[33] ) == FIB->fib_Size) ){
  1207.         FIB->fib_Size = ATUL( &FIB->fib_Comment[42] );
  1208.         debug(("XpkFastModifyFIB: header valid, size: %ld\n",FIB->fib_Size));
  1209.             return TRUE;
  1210.     }
  1211.  
  1212.     return FALSE;
  1213. }
  1214.  
  1215. BOOL XpkObjExamine( glb glob, struct XpkLock *lock, struct FileInfoBlock *fib ){
  1216.     BOOL err;
  1217.     struct FileHandle *xfh;
  1218.     
  1219.     debug(("XpkObjExamine(): "));
  1220.     err = xExamine(glob, lock->cfslock.xlock, fib);
  1221.     debug(("%ld,'%s'\n",err,fib->fib_FileName));
  1222.     if( !err ) return err;
  1223.  
  1224.     if( XpkFastModifyFIB( fib ) ) return DOSTRUE;
  1225.  
  1226.     xfh = xOpenFromCopyOfLock( glob, lock->cfslock.xlock );
  1227.     if( !xfh ){
  1228.         debug(("Error: XpkExamine(): Cannot open file from lock %lx.\n",lock));
  1229.         return DOSFALSE;
  1230.     }
  1231.     err = XpkModifyFIB( glob, lock, fib, xfh );
  1232.     if( !err ){
  1233.         LONG saveioerr;
  1234.  
  1235.         saveioerr = glob->ioerr;
  1236.         xClose( glob, xfh );
  1237.         glob->ioerr = saveioerr;
  1238.         return DOSFALSE;
  1239.     }else{
  1240.         xClose( glob, xfh );
  1241.         return DOSTRUE;
  1242.     }
  1243. }
  1244.  
  1245.  
  1246. BOOL XpkObjExamineFH( glb glob, struct XpkFH *fh, struct FileInfoBlock *fib ){
  1247.     BOOL err;
  1248.     
  1249.     debug(("XpkObjExamineFH(): "));
  1250.     err = xExamineFH(glob, fh->cfsfh.xfh, fib);
  1251.     debug(("%ld,'%s'\n",err,fib->fib_FileName));
  1252.     if( !err ) return err;
  1253.  
  1254.     if( (strncmp( fib->fib_Comment, XFH_ID, 5 ) == 0) &&
  1255.             (strlen( fib->fib_Comment ) == 50) ) fib->fib_Comment[0] = '\0';
  1256.         fib->fib_Size = fh->filelen;
  1257.  
  1258.     return DOSTRUE;
  1259. }
  1260.  
  1261.  
  1262. /* XpkModifyFIB() has to fix the length of the file. */
  1263. BOOL XpkModifyFIB( glb glob, struct XpkLock *lock,struct FileInfoBlock *fib, struct FileHandle *xfh ){
  1264.    struct XpkFib xpkfib;
  1265.    
  1266.    if( !XpkExamine_FH(glob, xfh, &xpkfib) ){
  1267.       debug(("Error: IsXpkFile: XpkExamine_FH returned error\n"));
  1268.       return FALSE;
  1269.    }
  1270.    fib->fib_Size = xpkfib.ULen;
  1271.    /* ToDo: Should NOT have fixed block size (look at UFS). */
  1272.    fib->fib_NumBlocks = (fib->fib_Size+BLOCKSIZE-1) / BLOCKSIZE;
  1273.  
  1274.    return DOSTRUE;
  1275. }
  1276.  
  1277.  
  1278. /*------------------------------------------------------------------------*
  1279.  * Initialise and cleanup functions.
  1280.  */
  1281.  
  1282. BOOL InitXpk( glb glob ){
  1283.   
  1284.   if(!(glob->XpkBase = OpenLibrary("xpkmaster.library",0L)))
  1285.       return FALSE;
  1286.    XpkBase = glob->XpkBase;
  1287.    if( ((struct Library *)glob->DOSBase)->lib_Version >= 36){
  1288.       glob->xpkport = NULL;
  1289.    }else{
  1290.       if(!(glob->xpkport=CreatePort("CFS port for KS1.3 Xpk-calls.",0L))){
  1291.          CloseLibrary(glob->XpkBase);
  1292.          debug(("Error creating xpk message port.\n"));
  1293.          return FALSE;
  1294.       }
  1295.    }
  1296.  
  1297.    return TRUE;
  1298. }
  1299.  
  1300.  
  1301. void CleanupXpk( glb glob ){
  1302.    
  1303.    if( glob->xpkport ) DeletePort( glob->xpkport );
  1304.    if( glob->XpkBase ) CloseLibrary( XpkBase );
  1305. }
  1306.  
  1307. /* xScan support */
  1308.  
  1309. static char *ULTA(char *Ptr,ULONG LW)
  1310.  
  1311. {
  1312.  UWORD Index;
  1313.  
  1314.  *Ptr++=' ';
  1315.  for (Index=0; Index<8; Index++, LW>>=4) Ptr[7-Index]='A'+(char)(LW&15);
  1316.  return &Ptr[8];
  1317. }
  1318.  
  1319. void xScan(glb glob,struct FileLock *ParentLock,char *Name)
  1320.  
  1321. {
  1322.  struct FileLock *xScanLock;
  1323.  struct FileHandle *xScanHandle;
  1324.  struct XpkFib XpkFib;
  1325.  
  1326.  if (!glob->xscan) return;
  1327.  
  1328.  debug (("xScan(%lx,%s)\n",ParentLock,Name));
  1329.  
  1330.  if (xScanLock=xLock(glob,ParentLock,Name,ACCESS_READ))
  1331.   {
  1332.    if (xExamine(glob,xScanLock,&glob->fib2))
  1333.     if (xScanHandle=xOpen(glob,ParentLock,Name,MODE_OLDFILE))
  1334.      {
  1335.       if (XpkExamine_FH(glob,xScanHandle,&XpkFib))
  1336.        if ((glob->fib2.fib_Comment[0]=='\0')||
  1337.            (strncmp(glob->fib2.fib_Comment,XFH_ID,strlen(XFH_ID))==0))
  1338.         {
  1339.          char *Ptr;
  1340.  
  1341.          Ptr=strcpy(glob->fib2.fib_Comment,XFH_ID)+strlen(XFH_ID);
  1342.          Ptr=ULTA(Ptr,glob->fib2.fib_Date.ds_Days);
  1343.          Ptr=ULTA(Ptr,glob->fib2.fib_Date.ds_Minute);
  1344.          Ptr=ULTA(Ptr,glob->fib2.fib_Date.ds_Tick);
  1345.          Ptr=ULTA(Ptr,glob->fib2.fib_Size);
  1346.          *ULTA(Ptr,(XpkFib.Type==XPKTYPE_PACKED)?XpkFib.ULen:glob->fib2.fib_Size)='\0';
  1347.  
  1348.          if (!xSetComment(glob,ParentLock,Name,glob->fib2.fib_Comment))
  1349.           debug (("failed to set new comment: %ld\n",glob->ioerr));
  1350.         }
  1351.        else debug (("Comment in use -- nothing done\n"));
  1352.       else debug (("failed to XpkExamine\n"));
  1353.  
  1354.       (void)xClose(glob,xScanHandle);
  1355.      }
  1356.     else debug (("failed to open file\n"));
  1357.    else debug (("failed to examine\n"));
  1358.  
  1359.    (void)xUnLock(glob,xScanLock);
  1360.   }
  1361.  else debug (("failed to open file\n"));
  1362. }
  1363.  
  1364. /* End of xpk.c */
  1365.